package hn.cch;

import hn.cch.kafka.ConsumerRunnable;
import hn.cch.kafka.ProducerRunnable;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;


public class KafkaApp {
    private static final Logger logger = LoggerFactory.getLogger(KafkaApp.class);

    public static String server = "192.168.10.169:9092";
    public static String topic = "topic";

    public static Integer timeout = 1000;


    public static void main(String[] args) {

        new Thread(new ProducerRunnable(server, topic)).start();
        new Thread(new ConsumerRunnable(server, topic)).start();

    }
}
